home *** CD-ROM | disk | FTP | other *** search
/ Chip 2004 December / 2004-12 CHIP.iso / Internet / NVU 0.50 for Windows / nvu-0.50-win32-installer-full.exe / {app} / chrome / comm.jar / content / editor / url-loader.js < prev    next >
Encoding:
Text File  |  2004-09-15  |  9.1 KB  |  321 lines
  1. /* ***** BEGIN LICENSE BLOCK *****
  2.  * Version: MPL 1.1/GPL 2.0/LGPL 2.1
  3.  *
  4.  * The contents of this file are subject to the Mozilla Public License Version
  5.  * 1.1 (the "License"); you may not use this file except in compliance with
  6.  * the License. You may obtain a copy of the License at
  7.  * http://www.mozilla.org/MPL/
  8.  *
  9.  * Software distributed under the License is distributed on an "AS IS" basis,
  10.  * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
  11.  * for the specific language governing rights and limitations under the
  12.  * License.
  13.  *
  14.  * The Original Code is The JavaScript Debugger.
  15.  *
  16.  * The Initial Developer of the Original Code is
  17.  * Netscape Communications Corporation.
  18.  * Portions created by the Initial Developer are Copyright (C) 1998-2003
  19.  * the Initial Developer. All Rights Reserved.
  20.  *
  21.  * Contributor(s):
  22.  *   Robert Ginda, <rginda@netscape.com>, original author
  23.  *   Daniel Glazman (glazman@disruptive-innovations.com), on behalf of Lindows.com
  24.  *
  25.  * Alternatively, the contents of this file may be used under the terms of
  26.  * either the GNU General Public License Version 2 or later (the "GPL"), or
  27.  * the GNU Lesser General Public License Version 2.1 or later (the "LGPL"),
  28.  * in which case the provisions of the GPL or the LGPL are applicable instead
  29.  * of those above. If you wish to allow use of your version of this file only
  30.  * under the terms of either the GPL or the LGPL, and not to allow others to
  31.  * use your version of this file under the terms of the MPL, indicate your
  32.  * decision by deleting the provisions above and replace them with the notice
  33.  * and other provisions required by the GPL or the LGPL. If you do not delete
  34.  * the provisions above, a recipient may use your version of this file under
  35.  * the terms of any one of the MPL, the GPL or the LGPL.
  36.  *
  37.  * ***** END LICENSE BLOCK ***** */
  38.  
  39.  
  40. const IOSERVICE_CTRID           = "@mozilla.org/network/io-service;1";
  41. const cnsIIOService             = Components.interfaces.nsIIOService;
  42. const SIS_CTRID                 = "@mozilla.org/scriptableinputstream;1"
  43. const cnsIScriptableInputStream = Components.interfaces.nsIScriptableInputStream;
  44. const cnsIChannel               = Components.interfaces.nsIChannel;
  45. const cnsIInputStream           = Components.interfaces.nsIInputStream;
  46. const cnsIRequest               = Components.interfaces.nsIRequest;
  47. const cnsIDirectoryListing      = Components.interfaces.nsIDirectoryListing;
  48.  
  49. var gError;
  50. var gCurrentChannel;
  51.  
  52. const FTP_DEL    = 0;
  53. const FTP_MKDIR  = 1;
  54. const FTP_RMDIR  = 2;
  55. const FTP_RENAME = 3;
  56.  
  57. function progressListener(aChannel, aAction, aUrl, aNewName)
  58. {
  59.   this.startup(aChannel, aAction, aUrl, aNewName);
  60. }
  61.  
  62. progressListener.prototype =
  63. {
  64.  
  65.   mChannel : null,
  66.   mAction : null,
  67.   mUrl : null,
  68.   mNewName : null,
  69.  
  70.   startup : function(aChannel, aAction, aUrl, aNewName)
  71.   {
  72.     mChannel = aChannel;
  73.     mAction = aAction;
  74.     mUrl = aUrl;
  75.     mNewName = aNewName;
  76.   },
  77.  
  78.   onStatus : function(aRequest, aContext, aStatus, aStatusArg)
  79.   {
  80.     if (aStatus == 4915228)
  81.     {
  82.       if (!gError)
  83.       {
  84.         switch (mAction)
  85.         {
  86.           case FTP_DEL:
  87.           case FTP_RMDIR:
  88.             DeleteSelectedItem();
  89.             break;
  90.           case FTP_MKDIR:
  91.             AppendNewDir(mUrl, mNewName);
  92.             break;
  93.           case FTP_RENAME:
  94.             RenameTo(mNewName);
  95.             break;
  96.           default:
  97.             break;
  98.         }
  99.       }
  100.       // close the channel
  101.       mChannel.cancel(0x804b0002); // NS_BINDING_ABORTED
  102.       EndFtpRequest();
  103.     }
  104.   },
  105.  
  106.   onProgress : function(aRequest, aContext,
  107.                         aProgress, aProgressMax)
  108.   {
  109.   },
  110.  
  111.   QueryInterface : function(aIID)
  112.   {
  113.     if (aIID.equals(Components.interfaces.nsIProgressEventSink)
  114.     || aIID.equals(Components.interfaces.nsIInterfaceRequestor)
  115.     || aIID.equals(Components.interfaces.nsISupports)
  116.     || aIID.equals(Components.interfaces.nsISupportsWeakReference)
  117.     || aIID.equals(Components.interfaces.nsIPrompt))
  118.       return this;
  119.     throw Components.results.NS_NOINTERFACE;
  120.   },
  121.  
  122.   getInterface : function(aIID)
  123.   {
  124.     if (aIID.equals(Components.interfaces.nsIProgressEventSink)
  125.     || aIID.equals(Components.interfaces.nsIInterfaceRequestor)
  126.     || aIID.equals(Components.interfaces.nsISupports)
  127.     || aIID.equals(Components.interfaces.nsISupportsWeakReference)
  128.     || aIID.equals(Components.interfaces.nsIPrompt))
  129.       return this;
  130.     throw Components.results.NS_NOINTERFACE;
  131.   },
  132.  
  133. // nsIPrompt
  134.   alert : function(dlgTitle, text)
  135.   {
  136.     var promptService = Components.classes["@mozilla.org/embedcomp/prompt-service;1"]
  137.                         .getService(Components.interfaces.nsIPromptService);
  138.     promptService.alert(window, dlgTitle, text);
  139.     gError = true;
  140.   },
  141.   alertCheck : function(dialogTitle, text, checkBoxLabel, checkObj)
  142.   {
  143.   },
  144.   confirm : function(dlgTitle, text)
  145.   {
  146.   },
  147.   confirmCheck : function(dlgTitle, text, checkBoxLabel, checkObj)
  148.   {
  149.   },
  150.   confirmEx : function(dlgTitle, text, btnFlags, btn0Title, btn1Title, btn2Title, checkBoxLabel, checkVal)
  151.   {
  152.   },
  153.   prompt : function(dlgTitle, text, inoutText, checkBoxLabel, checkObj)
  154.   {
  155.   },
  156.   promptPassword : function(dlgTitle, text, pwObj, checkBoxLabel, savePWObj)
  157.   {
  158.   },
  159.   promptUsernameAndPassword : function(dlgTitle, text, userObj, pwObj, checkBoxLabel, savePWObj)
  160.   {
  161.   },
  162.   select : function(dlgTitle, text, count, selectList, outSelection)
  163.   {
  164.   },
  165. }
  166.  
  167.  
  168. function _getChannelForURL (url)
  169. {
  170.     var serv = Components.classes[IOSERVICE_CTRID].getService(cnsIIOService);
  171.     if (!serv)
  172.         return null;
  173.     
  174.     return serv.newChannel(url, null, null);
  175.  
  176. }
  177.  
  178. function StreamListener(channel, url, observer)
  179. {
  180.     this.channel = channel;
  181.     this.data = "";
  182.     this.url = url;
  183.     this.observer = observer;
  184. }
  185.  
  186. StreamListener.prototype.onStartRequest =
  187. function (request, context)
  188. {
  189. }
  190.  
  191. StreamListener.prototype.onStopRequest =
  192. function (request, context, status)
  193. {
  194.     // close the channel
  195.     this.channel.cancel(0x804b0002); // NS_BINDING_ABORTED
  196.  
  197.     if (typeof this.observer.onComplete == "function")
  198.         this.observer.onComplete (this.data, this.url, status);
  199. }
  200.  
  201. StreamListener.prototype.onDataAvailable =
  202. function (request, context, inStr, sourceOffset, count)
  203. {
  204.     // dump ("onDataAvailable(): " + count + "\n");
  205.     // sometimes the inStr changes between onDataAvailable calls, so we
  206.     // can't cache it.
  207.     var sis = 
  208.         Components.classes[SIS_CTRID].createInstance(cnsIScriptableInputStream);
  209.     sis.init(inStr);
  210.     this.data += sis.read(count);
  211. }
  212.  
  213.  
  214.  
  215. function loadURLAsync (url, observer)
  216. {
  217.   var chan = _getChannelForURL (url);
  218.   chan.loadFlags |= cnsIRequest.LOAD_BYPASS_CACHE;
  219.   
  220.   var directoryListing = chan.QueryInterface(cnsIDirectoryListing);
  221.   directoryListing.listFormat = cnsIDirectoryListing.FORMAT_HTTP_INDEX;
  222.  
  223.   gCurrentChannel = chan;
  224.  
  225.   return chan.asyncOpen (new StreamListener (chan, url, observer), null);
  226. }
  227.  
  228. function deleteURLAsync (url)
  229. {
  230.   var chan = _getChannelForURL (url);
  231.   chan.loadFlags |= cnsIRequest.LOAD_BYPASS_CACHE;
  232.  
  233.   chan instanceof Components.interfaces.nsIFTPChannel;
  234.   var p = new progressListener(chan, FTP_DEL, url, "")
  235.   chan.notificationCallbacks = p.QueryInterface(Components.interfaces.nsIInterfaceRequestor) ;
  236.   chan.deleteFile();
  237.   gError = false;
  238.  
  239.   gCurrentChannel = chan;
  240.  
  241.   return chan.asyncOpen (null, null);
  242. }
  243.  
  244. function removeDirURLAsync (url)
  245. {
  246.   var chan = _getChannelForURL (url);
  247.   chan.loadFlags |= cnsIRequest.LOAD_BYPASS_CACHE;
  248.  
  249.   chan instanceof Components.interfaces.nsIFTPChannel;
  250.   var p = new progressListener(chan, FTP_RMDIR, url, "")
  251.   chan.notificationCallbacks = p.QueryInterface(Components.interfaces.nsIInterfaceRequestor) ;
  252.   chan.removeDirectory();
  253.   gError = false;
  254.  
  255.   gCurrentChannel = chan;
  256.  
  257.   return chan.asyncOpen (null, null);
  258. }
  259.  
  260. function createDirURLAsync (url, aDirName)
  261. {
  262.   var chan = _getChannelForURL (url);
  263.   chan.loadFlags |= cnsIRequest.LOAD_BYPASS_CACHE;
  264.  
  265.   chan instanceof Components.interfaces.nsIFTPChannel;
  266.   var p = new progressListener(chan, FTP_MKDIR, url, aDirName)
  267.   chan.notificationCallbacks = p.QueryInterface(Components.interfaces.nsIInterfaceRequestor) ;
  268.   chan.createDirectory();
  269.   gError = false;
  270.  
  271.   gCurrentChannel = chan;
  272.  
  273.   return chan.asyncOpen (null, null);
  274. }
  275.  
  276. function renameURLAsync(url, aName)
  277. {
  278.   var chan = _getChannelForURL (url);
  279.   chan.loadFlags |= cnsIRequest.LOAD_BYPASS_CACHE;
  280.  
  281.   chan instanceof Components.interfaces.nsIFTPChannel;
  282.   var p = new progressListener(chan, FTP_RENAME, url, aName)
  283.   chan.notificationCallbacks = p.QueryInterface(Components.interfaces.nsIInterfaceRequestor) ;
  284.   chan.renameTo(aName);
  285.   gError = false;
  286.  
  287.   gCurrentChannel = chan;
  288.  
  289.   return chan.asyncOpen (null, null);
  290. }
  291.  
  292. function loadURL(url, caller)
  293. {
  294.   function onComplete(data, url, status)
  295.     {
  296.       if (status == Components.results.NS_OK)
  297.       {
  298.         if (caller.parseData)
  299.           caller.parseData(data, caller.rqData);
  300.         if (caller.endCallback)
  301.           caller.endCallback();
  302.       }
  303.       else
  304.         caller.errorCallback(url, status);
  305.     };
  306.  
  307.   loadURLAsync (url, { onComplete: onComplete });
  308. }
  309.  
  310. function DropFtpConnection()
  311. {
  312.   if (gCurrentChannel)
  313.     gCurrentChannel.cancel(0x804b0002); // NS_BINDING_ABORTED
  314. }
  315.  
  316. function ForgetAboutLastFtpRequest()
  317. {
  318.   gCurrentChannel = null;
  319. }
  320.  
  321.